package com.learn.demo1;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.Message;

/**
 * Created by 郑靖 on 2017/9/21.
 */
//@EnableBinding(Sink.class)
public class DemoStreamListener {

    @StreamListener(Sink.INPUT)
    public void receiver(Message<?> message){
        System.err.println("receive payload:" + message.getPayload());
    }
}
